//package com.yuntsg.paperana.utils.esutils;
//
//import cn.hutool.db.Db;
//import cn.hutool.db.Entity;
//import co.elastic.clients.elasticsearch.ElasticsearchClient;
//import co.elastic.clients.elasticsearch.core.BulkResponse;
//import co.elastic.clients.elasticsearch.core.bulk.BulkOperation;
//import lombok.SneakyThrows;
//
//import java.io.IOException;
//import java.util.ArrayList;
//import java.util.List;
//
///**
// * @Author: gcr
// * @Date: 2023/8/30 15:22
// */
//public class EsInsert {
//    @SneakyThrows
//    public static void main(String[] args) {
//        // 入库
//
//        Db use = Db.use();
//        ElasticsearchClient client = EsClient.client();
//        List<Entity> query = use.query("select * from pmid_pdf_sentence_copy");
//        List<BulkOperation> bulkOperations = new ArrayList<>();
//        for (Entity entity : query) {
//            Integer id = entity.getInt("id");
//            String str = entity.getStr("str");
//            EsEntity esEntity = new EsEntity();
//            esEntity.setId(id);
//            esEntity.setStrcntest(str);
//            bulkOperations.add(new BulkOperation.Builder().create(d -> d.document(esEntity).id("" + (esEntity.getId()))).build());
//        }
//        BulkResponse result = null;
//        try {
//            result = client.bulk(e -> e.index(IndexConfig.UNIT_INDEX).operations(bulkOperations));
//        } catch (IOException e) {
//            e.printStackTrace();
//        }
//        if (result.errors()) {
//            System.out.println(result);
//            return;
//        }
//        EsClient.clientOff();
//
//    }
//}
